package net.com.client.test;

import java.io.IOException;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.MessageProperties;

public class EmitLogTopic {

	private static final String EXCHANGE_NAME = "topic_logs";

    public static void main(String[] argv)
                  throws Exception {

        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        channel.exchangeDeclare(EXCHANGE_NAME, "topic");
        
        argv = new String[]{"kern.iems","keys.critical"};
        String[] messages = new String[]{"kankan","133@"};
        for(int i=0;i<2;i++){
        	String arg = argv[i];
        	String message = messages[i];
//        	channel.
        	channel.basicPublish(EXCHANGE_NAME, arg,MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
            System.out.println(" [x] Sent '" + arg + "':'" + message + "'");
        }                                      
        connection.close();
    }
    
    private static String getRouting(String argv) {
		return null;
	}

	private static String getSeverity(String[] argv) {
		return "info0";
	}
	private static String getMessage(String[] strings) {
		if(strings.length<1)return "HelloWorld";
		return joinStrings(strings,"");
	}
	private static String joinStrings(String[] strings, String delimiter) {
		int length = strings.length;
		if(length==0) return "";
		StringBuilder words = new StringBuilder(strings[0]);
		for(int i=1;i<length;i++){
			words.append(strings[i]);
		}
		return words.toString();
	}
}
